package com.example.springcloud.streamconsumers.consumer.my;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.SubscribableChannel;

/**
 *
 * 自定义一个类似于 {@link Sink} 类
 *
 *   定义完这个类后yml文件需要修改：
 *    spring:
 *      cloud:
 *     stream:
 *       kafka:
 *         binder:
 *           brockers: localhost:9092 #指定kafka的位置
 *           zk-nodes: localhost:2181 #指定zk的位置
 *           auto-create-topics: true #设置为自动创topics，不然会出现topics没有创建，就进行了调用
 *       bindings:
 *           myInput: # 消费者 实际对应@Input("myInput") 中的myInput字样
 *             destination: stream-dome #把生产的消息放入哪个topics里面
 *             content-type: text/plain #消息类型，就是发送的消息的格式
 *
 *  才能接收到 myInput 消息通道的消息
 *
 * weiximei on 2018/8/25
 */
public interface MySink {

    String INPUT = "myInput";

    @Input(MySink.INPUT)
    SubscribableChannel myInput();

}
